package com.xuliugen.rocketmq.springboot.starter.consumer;

/**
 * RocketMQ消费者监听器
 * @author xuliugen
 */
public interface RocketMQListener<T> {

    /**
     * 消费者监听器回调方法，执行具体的消费者逻辑
     * @param message 消息实体对象
     */
    void onMessage(T message);
}
